package com.zr.springcloudstream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by Lx on 2018/7/6.
 * @Input注解表示输入通道，当前应用将接收消息；
 * 对应的@Output注解表示输出通道，当前应用将发送消息；
 * 注解参数表示通道的名称，如果不提供名称，则当前注解方法名即作为通道名称；
    必须以SubscribableChannel作为返回类型；
 */
public interface StreamClient {
    @Input("myMessage0914")
    SubscribableChannel input();

    @Output("outPutOrder0914")
    MessageChannel output();
}
